package com.heima.common.contants;

public class KafkaConstants {

    /**
     * 自媒体文章自动审核主题
     */
    public static final String WM_NEWS_AUTO_SCAN_TOPIC = "wm.news.auto.scan.topic";

    /**
     * 自媒体文章上下架的主题
     */
    public static final String WM_NEWS_UP_OR_DOWN_TOPIC = "wm.news.up.down.topic";

    /**
     * 文章同步到ES的主题
     */
    public static final String AP_ARTICLE_ES_SYNC_TOPIC = "ap.article.es.sync.topic";


    /**
     * 用户行为数据采集topic
     */
    public static final String HOT_ARTICLE_BEHAVIOR_TOPIC_INPUT = "hot.article.behavior.topic.input";

    /**
     * 行为数据聚合结果输出的topic
     */
    public static final String HOT_ARTICLE_BEHAVIOR_TOPIC_OUTPUT = "hot.article.behavior.topic.output";
}